package cn.hallele.leinsteining.mc.infrastructure.message.kafka.serialization;

import cn.hallele.leinsteining.mc.infrastructure.message.utils.CodecUtil;
import org.apache.kafka.common.serialization.Serializer;

/**
 * GGSSerializer
 *
 * @author anle5
 * @since 2023/12/9 星期六 0:29
 */
public class LSerializer implements Serializer<Object> {
    @Override
    public byte[] serialize(String topic, Object data) {
        return CodecUtil.bean2Byte(data);
    }
}
